// 引入数据库
let mysql=require('mysql');
// 创建一个mysql连接对象，里面设置好连接数据库的配置
let connection = mysql.createConnection({
    host     : 'localhost',
    user     : 'root',
    password : 'root',
    database : 'blog'
  });
//   连接数据库
connection.connect();
module.exports={
     // 定义一个根据username查找数据的函数
     getUserName:(username,callback)=>{
        // 查询数据是否存在的sql语句
        let sleStr="select * from users where username = ? ";
        connection.query(sleStr,[username],(err,result)=>{
            if(err) return callback(err,null)
            callback(null,result);

        })
    },
    // 定义一个插入数据的函数
    addUser:(newUser,callback) => {
        // 插入数据的sql语句
        let sqlStr="insert into users set ?";
        connection.query(sqlStr,newUser,(err,result)=>{
            if(err) return callback(err,null)
            callback(null,result);

        })
    },
   
    // 处理用户登录的信息
    userLogin:(userobj,callback)=>{
        let strSql="select * from users where username=? and password=?";
        connection.query(strSql,[userobj.username,userobj.password],(err,result)=>{
            if(err) return callback(err,null);
            callback(null,result);
        })
    }
}